class EventEmitter {
    constructor() {
        // 用于存储事件类型及其对应的处理函数列表
        this.events = {};
    }

    /**
     * 订阅事件
     * @param {string} eventType 事件类型
     * @param {function} handler 事件处理函数
     */
    subscribe(eventType, handler) {
        if (!this.events[eventType]) {
            this.events[eventType] = [];
        }
        this.events[eventType].push(handler);
    }

    /**
     * 取消订阅事件
     * @param {string} eventType 事件类型
     * @param {function} handler 要移除的事件处理函数
     */
    unsubscribe(eventType, handler) {
        if (!this.events[eventType]) {
            return;
        }
        const index = this.events[eventType].indexOf(handler);
        if (index !== -1) {
            this.events[eventType].splice(index, 1);
        }
    }

    /**
     * 发布事件
     * @param {string} eventType 事件类型
     * @param {...any} args 传递给处理函数的参数
     */
    publish(eventType, ...args) {
        if (!this.events[eventType]) {
            return;
        }
        // 遍历执行所有订阅了该事件的处理函数
        this.events[eventType].forEach(handler => {
            try {
                handler.apply(null, args); // 使用 apply 传递参数
            } catch (e) {
                console.error(`Error in event handler for ${eventType}:`, e);
            }
        });
    }
}

// 示例用法
const emitter = new EventEmitter();

// 定义处理函数
const handler1 = (data) => {
    console.log('Handler 1 received:', data);
};

const handler2 = (msg, value) => {
    console.log('Handler 2 received:', msg, value);
};

// 订阅事件
emitter.subscribe('dataUpdate', handler1);
emitter.subscribe('message', handler2);
emitter.subscribe('message', (msg) => {
    console.log('Handler 3 (anonymous) received:', msg);
});

// 发布事件
console.log('Publishing dataUpdate...');
emitter.publish('dataUpdate', { userId: 123, status: 'online' });

console.log('\nPublishing message...');
emitter.publish('message', 'Hello subscribers!', 42);

// 取消订阅
emitter.unsubscribe('dataUpdate', handler1);

console.log('\nPublishing dataUpdate again...');
emitter.publish('dataUpdate', { newData: true }); // Handler 1 不再收到通知